订单结算

场景描述

设备上报的数据一般是数值类型的测量信息或者比较固定的设备信息。如果需要针对固定的信息进行动态的计算，就需要对外部数据进行关联（join）操作，如果自动售货机不保存价格信息只保存商品id，需要根据订单上报的商品id关联出价格信息进行订单结算。本文以订单结算的场景为例，详细说明如何使用组件编排进行流数据分析作业的编写以及流数据分析作业如何运作。

操作流程

1. 创建产品和设备

   • 参照示例说明>新建产品（MQTT）和设备章节创建产品，设备和产品功能属性。本示例创建了商品id（goodsId）和订单id（orderId）2个属性。

     

1. 创建输出表和维表

   • 使用数据库连接工具连接到配置的数据库，编写标准sql创建表。
   • 创建输出数据库表：test_out，包含如下5个字段：createTime,deviceId,orderId,goodsId,price。
   • 创建维表：goods_info,包含goodsId和price两个字段。

2. 新建任务

   • 登录边缘管理平台，通过 数据分析>数据分析管理>添加数据分析任务 创建如下任务：

     

3. 任务编辑

   • 设备输入配置：根据创建的产品，设备和属性选择相应的项，点确定。

     

   • 维表Join配置：选择需要关联的数据源表，关联条件和数据流字段。添加需要的维表字段，点确定。

     

   • 数据源输出配置：根据相应的输入字段，选择输出到对应的数据库表字段中，点击确定。

   说明：字段类型和数据库表字段类型必须兼容，否则会出现异常。

   

   任务编辑完成，点击右上角的保存按钮，保存任务。如果出现错误信息，则根据返回的错误信息更改配置，直到没有错误为止，否则提交任务时也不会成功。

4. 下发任务到边缘端

   • 按照示例说明>部署数据分析任务章节下发数据分析任务到相应边缘节点执行。

5. 模拟设备上传数据和查看运行结果

   • 参照实例说明>设备上报数据章节内容，开启模拟数据脚本，模拟设备上传数据。

   • 查看指定输出数据源中数据表数据：使用任意的数据库连接工具，连到输出数据源指定的数据库，查询相应的数据库表最新的数据，会出现相应的计算结果。